package cn.doitedu.demo3;

import cn.doitedu.beans.EventBean;
import org.apache.flink.api.common.functions.RuntimeContext;
import org.apache.flink.util.Collector;

import java.io.IOException;

/**
 * @Author: 深似海
 * @Site: <a href="www.51doit.com">多易教育</a>
 * @QQ: 657270652
 * @Date: 2024/5/14
 * @Desc: 学大数据，上多易教育
 *
 * 规则运算机接口
 *
 **/
public interface RuleCalculator {

    // 封装的就是demo1中的卸载flink的open中的逻辑
    public void init(RuntimeContext runtimeContext, String ruleParamJson );

    // 封装的就是demo1中的写在flink的processElement中的逻辑
    public void calc(EventBean eventBean, Collector<String> out) throws Exception;


    public String getRuleId();


}
